//package com.kafka.service.observer.impl;
//
///**
// * @descriptions:
// * @author: yunqiang
// * @date: 2022/1/5 15:46
// */
//
//import com.kafka.service.observer.Observer;
//
///**
// * 观察者
// * 实现了update方法
// * @author jstao
// *
// */
//public class User implements Observer {
//
//    private String name;
//    private String message;
//
//    public User(String name) {
//        this.name = name;
//    }
//
//    @Override
//    public void update(String message) {
//        this.message = message;
//        read();
//    }
//
//    public void read() {
//        System.out.println(name + " 收到推送消息： " + message);
//    }
//
//}
